package com.wenhai.disruptor.handler;

import com.lmax.disruptor.EventHandler;
import com.wenhai.disruptor.event.OrderEvent;

/**
 *
 *
 * @author wenhai
 * @date   2021/1/12
 */
public class OrderEventHandler implements EventHandler<OrderEvent> {

    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) {
        System.out.println("消费者：" + event.getId() + ", sequence = " + sequence + ", endOfBatch = " + endOfBatch);
    }
}
